004aca0bb7c7afd7aabf1e0b5f7bbbe8b9720738,modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java,GridIoManager,send,#ClusterNode#Object#number#Message#number#boolean#number#boolean#IgniteInClosure#,1252
Before Change
if (ordered)
processOrderedMessage(locNodeId, ioMsg, plc, null);
else
processRegularMessage0(ioMsg, locNodeId);
if (ackC != null)
ackC.apply(null);
After Change
if (ordered)
processOrderedMessage(locNodeId, ioMsg, plc, null);
else if (async) {
assert msg instanceof GridIoUserMessage : ioMsg; // Async execution was added only for IgniteMessaging.
processRegularMessage(locNodeId, ioMsg, plc, null);
}
else
processRegularMessage0(ioMsg, locNodeId);
if (ackC != null)
ackC.apply(null);